package com.wang.webSocket;

import com.wang.util.EmptyUtil;
import io.netty.channel.ChannelHandlerContext;

/**
 * @author wcy
 * @date 2022-07-30 10:40
 */
public class WebSocketUtil {

    //发送给测试客户端调试数据
    public static void sendTestData(String devGId, String data) {
        //判断全局变量中是否包含此设备
        if (WebSocketMap.clientDDCtxMap.containsKey(devGId)) {


            //获取连接
            ChannelHandlerContext ctx = WebSocketMap.clientDDCtxMap.get(devGId).getWebSocketConMsg().getCtx();

            if (EmptyUtil.isNotNull(data)) {
                WebOutBoundHander.outData(ctx, data);
            }


        }
        //判断全局变量中是否包含此设备
        if (WebSocketMap.clientWXCtxMap.containsKey(devGId)) {
            //获取连接
            ChannelHandlerContext ctx = WebSocketMap.clientWXCtxMap.get(devGId).getWebSocketConMsg().getCtx();

            if (EmptyUtil.isNotNull(data)) {
                WebOutBoundHander.outData(ctx, data);
            }

        }
        //判断全局变量中是否包含此设备
        if (WebSocketMap.clientWEBCtxMap.containsKey(devGId)) {
            //获取连接
            ChannelHandlerContext ctx = WebSocketMap.clientWEBCtxMap.get(devGId).getWebSocketConMsg().getCtx();

            if (EmptyUtil.isNotNull(data)) {
                WebOutBoundHander.outData(ctx, data);
            }

        }
    }


}
